package com.ydl.learning.flink.demo.pipeline.java.impl;

import com.ydl.learning.flink.demo.pipeline.java.Sink;
import org.apache.flink.streaming.api.datastream.DataStream;

/**
 *
 */
public class ConsoleSinkImpl<T> extends BaseProcedureImpl implements Sink<T> {

  /**
   * Default constructor
   */
  public ConsoleSinkImpl() {
  }

  /**
   *
   */
  @Override
  public void setSource(DataStream<T> source) {
    // TODO implement here
  }

  /**
   *
   */
  @Override
  public void sink() {
    // TODO implement here
  }

}